#!/usr/bin/env python
# -*- coding: UTF-8 -*-
"""
@Project ：Employment_class 
@File    ：15_apple堵塞式添加任务.py
@IDE     ：PyCharm 
@Author  ：XiaoDengYa
@Date    ：2021/6/6/006 20:56 
"""

import os
import time
from multiprocessing import Pool


def worker(num):
    for i in range(5):
        print("===pid=%d==num=%d=" % (os.getpid(), num))
        time.sleep(1)


if __name__ == '__main__':

    # 3表示 进程池中对多有3个进程一起执行
    pool = Pool(3)

    for i in range(10):
        print("---%d---" % i)
        pool.apply(worker, (i,)) # 堵塞 执行完之后依次执行，要等待条件满足之后才能继续执行
    pool.close()
    pool.join()
